package xin.marcher.wind.migrate.domain.entity;

import lombok.Data;
import lombok.EqualsAndHashCode;
import xin.marcher.framework.mybatis.dataobject.BaseDO;

/**
 * binlog 消息同步消费记录表
 */
@Data
@EqualsAndHashCode(callSuper = true)
public class EtlBinlogConsumeRecordDO extends BaseDO {

    /**
     * 主键
     */
    private Long id;

    /**
     * 消息队列 id（即：queueId）
     */
    private Integer queueId;

    /**
     * 消息偏移量（唯一定位该消息在队列中的位置）
     */
    private Long offset;

    /**
     * 消息所属主题
     */
    private String topic;

    /**
     * 消息所在 broker 名称
     */
    private String brokerName;

    /**
     * 消费状态: 0-未消费 1-消费成功 2-已提交
     * @see  xin.marcher.wind.migrate.enums.ConsumerStatus
     */
    private Integer consumeStatus;

}
